end conversation @dialog_id;
begin transaction

declare @dialog_id uniqueidentifier

Update inventory set Quantity = @amount where TitleId = @title;
--create procedure to receive message and update table

Update inventory set Quantity = @amount where TitleId = @title;
declare @message_body xml
Create table inventory
set @title = @message_body.value('(/InventoryUpdate/TitleId)[1]','nvarchar(100)');
go

复制代码 代码如下:

复制代码 代码如下:

use Inventory
declare @title nvarchar(128);
begin transaction
创建合约
);
use master
--send message

数据同时被更新了

@dialog_id = conversation_handle,

复制代码 代码如下:

create proc InventoryProc as

print 'b:'+@title;
go

复制代码 代码如下:

队列监听
use Inventory
declare @dialog_id uniqueidentifier
创建队列与服务
primary key (TitleId,Quantity)
@message_body = message_body

print 'handle is' + cast(@dialog_id as nvarchar(90))
Create Message Type [//mark/v10/types/inventoryresponse]
go
step 2: 创建整个SSB的基础框架.

declare @title nvarchar(128);
(


from service [//mark/v10/services/inventory client]
commit transaction;
<Quantity>102</Quantity>
[//mark/v10/contracts/inventorycontract]
print 'message body is' + cast(@message_body as nvarchar(max) )
Create contracts [//mark/v10/contracts/inventorycontract]

@message_body = message_body
<TitleId>pc1001</TitleId>

declare @amount int;
set @title = @message_body.value('(/InventoryUpdate/TitleId)[1]','nvarchar(100)');
(
</InventoryUpdate>'

use Inventory

Quantity int not null,
if(@dialog_id is not null)
print 'message body is' + cast(@message_body as nvarchar(max) )
操作成功后再去查询inventory queue的表 犹豫里面的数据已经被receive 出来 就为空了。

[//mark/v10/types/inventory] send by initiator,

insert inventory values ('pc1003',300);
commit transaction;

);

首先建立个存储过程，（把receive 中的那段代码拿过来就可以了）
to service '//mark/v10/services/inventory'
print 'handle is' + cast(@dialog_id as nvarchar(90))
go

Create Message Type [//mark/v10/types/inventory]

setp 4: 从 inventory queue 中获取信息并更新数据

create service [//mark/v10/services/inventory client]
declare @message_body xml
end

set @amount = @message_body.value('(/InventoryUpdate/Quantity)[1]','int');
waitfor(
go
print 'a:'+cast(@amount as nvarchar(100))

复制代码 代码如下:

send on conversation @dialog_id message type [//mark/v10/types/inventory]
receive
receive

on contract [//mark/v10/contracts/inventorycontract]

select conversation_handle, cast(message_body as xml) as conversation_body from [Inventory queue]
'<InventoryUpdate>
commit transaction;

begin

go

go

declare @amount int;
step 3：发送消息到消息队列中

复制代码 代码如下:

print 'a:'+cast(@amount as nvarchar(100))

end conversation @dialog_id;

declare @dialog_id uniqueidentifier
);
insert inventory values ('pc1002',200);
begin dialog conversation @dialog_id
create queue [inventory queue];
go
begin

复制代码 代码如下:

其中conversation_body 就是 我们发出的信息了。

set @amount = @message_body.value('(/InventoryUpdate/Quantity)[1]','int');
use inventory

首先创建信息类型

begin transaction
go
step 5: 接下来做个自动监听功能，只要有信息发送到队列，相关队列，就可以自动执行功能.

--create inventory service
(
print 'b:'+@title;
这里只是查询了两列。
@dialog_id = conversation_handle,
(
from [dbo].[Inventory queue]),timeout 5000;
create queue [inventory client queue];
);

复制代码 代码如下:

from [dbo].[Inventory queue]

insert inventory values ('pc1004',400);

insert inventory values ('pc1001',100);
end

TitleId nvarchar(6) not null,
if(@dialog_id is not null)

create service [//mark/v10/services/inventory]

on queue [inventory client queue]

step 1：perpar database & data
发送成功后，可以查询 inventory_queue
with encryption = off;

复制代码 代码如下:

[//mark/v10/types/inventoryresponse] send by target
Create database Inventory
on queue [inventory queue]